package com.spark.demostream.consumer;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * @author fuqiang
 * @Description 消费者
 * @Date 2020/10/23
 */
public interface ReceviceMsg2 {

    String INPUT_CHANNEL = "input_channel2";

    /**
     * 接收信息
     */
    @Input(ReceviceMsg2.INPUT_CHANNEL)
    SubscribableChannel receive();
}
